# -*- coding: utf-8 -*-

from multiprocessing import Queue

# 占用的内存，最好小数据，消息数据，下载地址
# Queue(限制队列里面的个数)  先进先出
q = Queue(3)
# 添加
q.put('a')
q.put('b')
q.put({'a': 2})
print('篮子满了')   # 队列满了，相当于锁了
# 提取
print(q.get())
print(q.get())
print(q.get())
# # 队列为空，等待加入，也会阻塞，相当于锁了
print('队列为空')
print(q.get())
